type google.golang.org/grpc/internal/transport.loopyWriter
24 uses
google.golang.org/grpc/internal/transport (current package)
controlbuf.go#L508: type loopyWriter struct {
controlbuf.go#L535: func newLoopyWriter(s side, fr *framer, cbuf *controlBuffer, bdpEst *bdpEstimator, conn net.Conn, logger *grpclog.PrefixLogger, goAwayHandler func(*goAway) (bool, error), bufferPool mem.BufferPool) *loopyWriter {
controlbuf.go#L537: l := &loopyWriter{
controlbuf.go#L579: func (l *loopyWriter) run() (err error) {
controlbuf.go#L636: func (l *loopyWriter) outgoingWindowUpdateHandler(w *outgoingWindowUpdate) error {
controlbuf.go#L640: func (l *loopyWriter) incomingWindowUpdateHandler(w *incomingWindowUpdate) {
controlbuf.go#L657: func (l *loopyWriter) outgoingSettingsHandler(s *outgoingSettings) error {
controlbuf.go#L661: func (l *loopyWriter) incomingSettingsHandler(s *incomingSettings) error {
controlbuf.go#L666: func (l *loopyWriter) registerStreamHandler(h *registerStream) {
controlbuf.go#L677: func (l *loopyWriter) headerHandler(h *headerFrame) error {
controlbuf.go#L713: func (l *loopyWriter) originateStream(str *outStream, hdr *headerFrame) error {
controlbuf.go#L731: func (l *loopyWriter) writeHeader(streamID uint32, endStream bool, hf []hpack.HeaderField, onWrite func()) error {
controlbuf.go#L777: func (l *loopyWriter) preprocessData(df *dataFrame) {
controlbuf.go#L791: func (l *loopyWriter) pingHandler(p *ping) error {
controlbuf.go#L799: func (l *loopyWriter) outFlowControlSizeRequestHandler(o *outFlowControlSizeRequest) {
controlbuf.go#L803: func (l *loopyWriter) cleanupStreamHandler(c *cleanupStream) error {
controlbuf.go#L832: func (l *loopyWriter) earlyAbortStreamHandler(eas *earlyAbortStream) error {
controlbuf.go#L858: func (l *loopyWriter) incomingGoAwayHandler(*incomingGoAway) error {
controlbuf.go#L869: func (l *loopyWriter) goAwayHandler(g *goAway) error {
controlbuf.go#L881: func (l *loopyWriter) handle(i any) error {
controlbuf.go#L919: func (l *loopyWriter) applySettings(ss []http2.Setting) {
controlbuf.go#L943: func (l *loopyWriter) processData() (bool, error) {
http2_client.go#L81: loopy *loopyWriter
http2_server.go#L77: loopy *loopyWriter